package com.apex.flink.sink;

import org.apache.flink.api.common.serialization.SerializationSchema;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.connector.jdbc.internal.options.JdbcOptions;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
import org.apache.flink.table.data.RowData;

public class HiveSinkFunction extends RichSinkFunction<RowData> {
    private static final long serialVersionUID = 1L;
    private final JdbcOptions jdbcOptions;
    private final SerializationSchema<RowData> serializationSchema;

    public HiveSinkFunction(JdbcOptions jdbcOptions, SerializationSchema<RowData> serializationSchema) {
        this.jdbcOptions = jdbcOptions;
        this.serializationSchema = serializationSchema;
    }

    @Override
    public void open(Configuration parameters) throws Exception {
        super.open(parameters);
    }

    @Override
    public void invoke(RowData value, Context context) throws Exception {

    }

    @Override
    public void close() throws Exception {
        super.close();
    }
}
